package com.xxl.job.executor.vehicle.service;

import com.xxl.job.executor.hktv.basics.HikVisionService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

/**
 * @Description: 创建线程任务服务
 * @Author SONGtiank
 * @Date: 2020/11/3 16:55
 * @Version: 1.0
 */
@Service
public class CustomMultiThreadingService {
    private Logger logger = LoggerFactory.getLogger(CustomMultiThreadingService.class);
    /**
     * @Description:通过@Async注解表明该方法是一个异步方法，
     * 如果注解在类级别上，则表明该类所有的方法都是异步方法，而这里的方法自动被注入使用ThreadPoolTaskExecutor作为TaskExecutor
     * @Author SONGtiank
     * @Date: 2020/11/2 16:55
     * @Version: 1.0
     * @Throws
     * @param m_ip
     */
    @Async
    public  void executeAysncTask1(String m_ip) throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);

    }
    @Async
    public void executeAsyncTask2(String m_ip)throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);
    }
    @Async
    public void executeAsyncTask3(String m_ip)throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);
    }
    @Async
    public void executeAsyncTask4(String m_ip)throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);
    }
    @Async
    public void executeAsyncTask5(String m_ip)throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);
    }
    @Async
    public void executeAsyncTask6(String m_ip)throws InterruptedException{
        HikVisionService hikVisionService = new HikVisionService();
        hikVisionService.initMemberFlowUpload(m_ip, 100);
    }
  }